import os
from celery import Celery


#指定django设置文件(注意:需要在创建celery对象之前指定)
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

#创建celery应用(通常一个项目就创建一个celery应用就可以了)
#参数1.自定义应用名
#参数2:指定使用redis来保存celery任务
celery_app = Celery('meiduo',
                    backend='redis://127.0.0.1:6379/14',
                    broker='redis://127.0.0.1:6379/15')

#指定对应的包,扫描celery任务
celery_app.autodiscover_tasks(['celery_tasks.sms',
                               'celery_tasks.email',
                               'celery_tasks.html'])

#celery_app  = Celery('meiduo')
# #读取配置文件
#celery_app.config_from_object('celery_tasks.config')
